---
version: 2.2
pipelines:
  - id: pipeline1
    status: running
    name: pipeline1
    description: 'Generator to PostgreSQL'
    connectors:
      - id: generator-source
        type: source
        plugin: "builtin:generator"
        name: generator-source
        settings:
          recordCount: "10"
          # readTime: "1s"
          format.options: "id:int,name:string"
          format.type: "structured"

      - id: pg-destination
        type: destination
        plugin: "standalone:postgres"
        name: pg-destination
        settings:
          url: "postgresql://meroxauser:meroxapass@localhost/meroxadb?sslmode=disable"
          # table: "employees"
    
    processors:
      - id: "format-lines"
        plugin: "custom.javascript"
        settings:
          script: |
            function getRandomInt(max) {
              return Math.floor(Math.random() * max);
            }

            function getRandomBoolean() {
              return Math.random() < 0.5;

            }

            function process(rec) {
              rec.Key = RawData(JSON.stringify({"id": getRandomInt(1000)}));
              if (getRandomBoolean()) {
                rec.Metadata["opencdc.collection"] = "contractors"
              } else {
                rec.Metadata["opencdc.collection"] = "employees"
              }

              return rec;
            }